package nats

import (
	"gluenet/pkg/agent"
	"gluenet/pkg/agent/v2/rpc"
	"os"
)

var CLI agent.Agent

func Install() error {
	mode := os.Getenv("MODE")

	natsUrl := "nats://129.226.101.5:4222"
	if mode == "prod" {
		natsUrl = os.Getenv("NATS_SERVER")
	}

	cli, err := agent.NewAgent(&rpc.Config{
		NatsUrl: natsUrl,
	})
	if err != nil {
		return err
	}
	CLI = cli

	return nil
}
